package com.etlmaster.executor.steps.datax;

import com.etlmaster.executor.StepMeta;


/**
 * @author Wugf
 * @date 2016-11-10
 */
public class HbaseWriterStepMeta extends StepMeta{

	private String tableName;
	private String hbaseZookeeperHosts;
	private String hbaseZookeeperPorts;
	private String columns;
	private String rowKeyColumns;
	private String concurrency;
	public HbaseWriterStepMeta(String id, String name, String step_code,
			String sessionId, String paramStr) {
		super(id, name, step_code, sessionId, paramStr);
		// TODO Auto-generated constructor stub
	}

	@Override
	protected void loadParamsFromConfigTable() {
		// TODO Auto-generated method stub
		
	}

	public String getHbaseZookeeperPorts() {
		return variableSubstitution(hbaseZookeeperPorts);
	}

	public void setHbaseZookeeperPorts(String hbaseZookeeperPorts) {
		this.hbaseZookeeperPorts = hbaseZookeeperPorts;
	}

	public String getHbaseZookeeperHosts() {
		return variableSubstitution(hbaseZookeeperHosts);
	}

	public void setHbaseZookeeperHosts(String hbaseZookeeperHosts) {
		this.hbaseZookeeperHosts = hbaseZookeeperHosts;
	}

	public String getTableName() {
		return variableSubstitution(tableName);
	}

	public void setTableName(String tableName) {
		this.tableName = tableName;
	}

	public String getColumns() {
		return variableSubstitution(columns);
	}

	public void setColumns(String columns) {
		this.columns = columns;
	}

	public String getRowKeyColumns() {
		return variableSubstitution(rowKeyColumns);
	}

	public void setRowKeyColumns(String rowKeyColumns) {
		this.rowKeyColumns = rowKeyColumns;
	}

	public String getConcurrency() {
		return variableSubstitution(concurrency);
	}

	public void setConcurrency(String concurrency) {
		this.concurrency = concurrency;
	}

}
